af2eac079123f324b89c06966fd688a4c5e19432,src/main/java/com/continuuity/gateway/consumer/TupleWritingConsumer.java,TupleWritingConsumer,batch,#List#,53

Before Change


        destination = "default";
      }
      // construct the stream URI to use for the data fabric
      String queueURI = FlowStream.buildStreamURI(destination);
      operations.add(new QueueEnqueue(queueURI.getBytes(), bytes));
      LOG.debug("Sending tuple to " + queueURI + ", tuple = " + event);

After Change


        destination = "default";
      }
      // construct the stream URI to use for the data fabric
      String queueURI = FlowStream.buildStreamURI(destination).toString();
      operations.add(new QueueEnqueue(queueURI.getBytes(), bytes));
      LOG.debug("Sending tuple to " + queueURI + ", tuple = " + event);